//package com.weixin.engine.rabbitmq;
//
//import com.fasterxml.jackson.core.JsonProcessingException;
//import com.fasterxml.jackson.databind.ObjectMapper;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.amqp.rabbit.core.RabbitTemplate;
//import org.springframework.stereotype.Service;
//
//import javax.annotation.Resource;
//
//@Slf4j
//@Service
//public class MessageProducer {
//
//    private static final ObjectMapper mapper = new ObjectMapper();
//
//    @Resource
//    private RabbitTemplate pointRabbitTemplate;
//
//    /**
//     * 发送消息
//     *
//     * @param content
//     */
//    public void sendMessageToMq(String content) {
//        MessageDTO dto = new MessageDTO();
//        dto.setContent(content);
//        pointRabbitTemplate.convertAndSend(format(dto));
//    }
//
//    public String format(Object pojo) {
//        try {
//            return mapper.writeValueAsString(pojo);
//        } catch (JsonProcessingException e) {
//            log.error("JsonProcessingException, pojo = {}", pojo, e);
//            return "{}";
//        }
//    }
//}